package com.lxd.order.utils;

import com.lxd.order.pojo.MqLog;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class RabbitMq {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void consumeFanoutExchange(String exchangeName, MqLog message) {

        rabbitTemplate.convertAndSend(exchangeName,"",message);
    }
}
